package com.qsl.datax.plugin.reader.kafkareader;

public interface Key {

     String BOOTSTRAP_SERVERS="bootstrapServers";

     String TOPIC = "topic";

     String GROUP_ID = "groupId";
     String RETRIES = "retries";
     String MAX_POLL_RECORDS = "maxPollRecords";
     String KEY_DESERIALIZER = "keyDeserializer";
     String VALUE_DESERIALIZER = "valueDeserializer";
     String FIELD_DELIMITER = "fieldDelimiter";
     String POLL_TIMEOUT_MS = "pollTimeoutMs";

     String TOPIC_NUM_PARTITION = "topicNumPartition";

     String READ_TYPE= "readType";
     String COLUMN_TYPE = "columnType";

     String SASL = "sasl";
     String SASL_SECURITY_PROTOCOL = "securityProtocol";
     String SASL_MECHANISM = "mechanism";
     String SASL_USERNAME = "username";
     String SASL_PASSWORD = "password";
}
